package com.example.mq.mqserver.core;

import lombok.AllArgsConstructor;
import lombok.Data;

/**
 * 表示一个完整的消费者
 */
@Data
@AllArgsConstructor
public class ConsumerEnv {
    private String consumerTag;
    private String QueueName;
    private boolean autoAck;
    //通过这个回调函数 来处理收到的消息
    private Consumer consumer;

}
